package com.hsj.mq.activemq;


import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

/**
 * Active 自动从 消息队列里面 拿到消息并消费
 */
//@Component
public class ListenFromActiveMQ {

    @JmsListener(destination = "order.queue.id")//监听 队列， 有消息立即获取并处理
    @SendTo("order.insert.queue.id")   //接收到消息后执行下面的方法 并把返回值再发到 另一个对列里面去
    public String antoReceive(String id){
        System.out.println("接受到消息队列的消息，消费"+id);
        return "insert"+id;
    }
}
